package com.sanmubird.mywebframework.eventbus.core;

/**
 * 消息生产者。负责产生和发送消息到 Broker
 */
public interface MqPublisher {

    <T> void publish(MqMessage<T> mqMessage);

}
